package ifosup.marie.thread;

public class ProducteurMessage implements Runnable
{
	private ConsommateurMessage cm = new ConsommateurMessage();
		
	public ConsommateurMessage getCm() {
		return cm;
	}

	public void setCm(ConsommateurMessage cm) {
		this.cm = cm;
	}

	@Override
	public void run() 
	{
		
		while (true)
		{
			cm.envoi("message");
			try 
			{
				Thread.sleep(1000);
			} 
			catch (InterruptedException e) 
			{
				e.printStackTrace();
			}
		}	
	}

}
